package com.sencorsta.ids.queue;

public class MqMaker implements Runnable {

	@Override
	public void run() {
		int i=0;
		while (i<Integer.MAX_VALUE) {
			i++;
			try {
				Thread.sleep(100l);
				QueueTest.q.put(Thread.currentThread().getName()+" "+i);
				System.out.println("创造:"+Thread.currentThread().getName()+" "+i);
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
	}

}
